package com.lei.baselibrary.base.rx

import com.lei.baselibrary.base.common.ResultCode
import com.lei.baselibrary.base.data.protocol.BaseResp
import rx.Observable
import rx.functions.Func1
import java.util.*

/**
 * @ProjectName : MyMall
 * @Author : 雷金泷
 * @Time : 2021/2/25 11:28
 * @Description : 文件描述
 */
//通用数据类型转换封装
class BaseFunc<T> : Func1<BaseResp<T>,Observable<T>> {
    override fun call(t: BaseResp<T>): Observable<T> {
        if(t.status!=ResultCode.SUCCESS){
            return Observable.error(BaseException(t.status,t.Message))
        }
        return Observable.just(t.data)
    }

}